package som.simon.reactor;

import reactor.core.publisher.Flux;

public class FlatMapMain {

    public static void main(String[] args) {

        Flux.just(CustomConstants.NAMES)
                .log()
                .flatMap(name -> {
                    String[] names = name.split("");
                    return Flux.fromArray(names);
                }).log()
                .subscribe();

    }

}
